package camid.distribution.broker;

import camid.distribution.protocol.MethodRequestMessage;
import camid.distribution.protocol.MethodResponseMessage;
import camid.infrastructure.Connector;
import camid.infrastructure.SenderQueue;

public class MockSenderQueue extends SenderQueue 
{
	private Invoker invoker;
	
	public MockSenderQueue( Invoker invoker )
	{
		this.invoker = invoker;
	}

	public MethodResponseMessage doSend(Connector sender, MethodRequestMessage requestMessage)
	{
		MethodResponseMessage response = invoker.invoke(requestMessage);
		return response;	
	}
	
}
